package io.kiki.task.server.job.task.support.result.job;

import io.kiki.task.server.job.task.dto.BaseDTO;
import io.kiki.task.template.datasource.persistence.po.JobTask;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.extern.slf4j.Slf4j;

import java.util.List;

@Slf4j
@EqualsAndHashCode(callSuper = true)
@Data
public class JobExecutorResultContext extends BaseDTO {

    private Long workflowNodeId;
    private Long workflowTaskBatchId;
    private Integer jobOperationReason;
    private boolean isRetry;
    private List<JobTask> jobTaskList;

    /**
     * 是否开启创建Reduce任务
     */
    private boolean createReduceTask;

    /**
     * 是否更新批次完成
     */
    private boolean taskBatchComplete;


}
